package com.ruifu.conversions.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 消息队列配置，采用Direct
 * @author  lcq
 * @create 2019/9/17
 */
@Configuration
public class DirectConfig {

    public static final String QUEUE = "notify.conversion";

    @Bean
    public Queue conversionNotifyQueue() {
        return new Queue(QUEUE,true);
    }
}
